package com.atguigu.realtime.util;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class RedisUtil {
    private static JedisPool pool;

    static {
        JedisPoolConfig conf = new JedisPoolConfig();
        conf.setMaxTotal(300); // 提供的最大redis连接数
        conf.setMaxIdle(10); // 允许的最大空闲连接数
        conf.setMaxWaitMillis(10000); // 获取连接的最大等待时间
        conf.setTestOnCreate(true);     // 创建的时候测试一下
        conf.setTestOnBorrow(true);  // 测试redis服务连接
        conf.setTestOnReturn(true); //归还的时候测试一下
        pool = new JedisPool(conf, "hadoop162", 6379);
    }

    public static Jedis getRedisClient() {
        // 获取数据的对象
        Jedis jedis = pool.getResource();
        // 设置redis数据 缓冲存储在数据库 1
        jedis.select(1);
        return jedis;
    }
}
